0df3bc9dec4bea1f330305619b42d3ba7994fd7f,eventstore/src/test/java/no/ks/eventstore2/eventstore/EventStoreProtoTest.java,EventStoreProtoTest,testActorRestarting,#,118
Before Change
mongodbJournal.saveEvent(new AggEvent("agg"));
TestActorRef<Actor> eventstore = TestActorRef.create(_system, EventStore.mkProps(mongodbJournal));
eventstore.tell(new Subscription("agg",null),super.testActor());
expectMsgClass(AggEvent.class);
expectMsgClass(CompleteSubscriptionRegistered.class);
eventstore.tell(new RemoveSubscription("agg"),super.testActor());
After Change
mongodbJournal.saveEvent(ProtobufHelper.newEventWrapper("agg", "1", -1, Order.SearchRequest.newBuilder().build()));
TestActorRef<Actor> eventstore = TestActorRef.create(_system, EventStore.mkProps(mongodbJournal));
eventstore.tell(Messages.Subscription.newBuilder().setAggregateType("agg").build(),super.testActor());
expectMsgClass(Messages.EventWrapper.class);
expectMsgClass(Messages.CompleteSubscriptionRegistered.class);
eventstore.tell(Messages.RemoveSubscription.newBuilder().setAggregateType("agg").build(),super.testActor());
expectMsgClass(Messages.SubscriptionRemoved.class);
eventstore.tell(ProtobufHelper.newEventWrapper("agg", "1", -1, Order.SearchRequest.newBuilder().build()),super.testActor());